@casual-simulation/rate-limit-redis

rate-limit-redis

A redis store for the express-rate-limit middleware.

Installation

From the npm registry:

# Using npm
> npm install rate-limit-redis
# Using yarn or pnpm
> yarn/pnpm add rate-limit-redis

From Github Releases:

# Using npm
> npm install https://github.com/wyattjoh/rate-limit-redis/releases/download/v{version}/rate-limit-redis.tgz
# Using yarn or pnpm
> yarn/pnpm add https://github.com/wyattjoh/rate-limit-redis/releases/download/v{version}/rate-limit-redis.tgz

Replace {version} with the version of the package that you want to your, e.g.: 3.0.0.

Usage

Importing

This library is provided in ESM as well as CJS forms, and works with both Javascript and Typescript projects.

This package requires you to use Node 14 or above.

Import it in a CommonJS project (type: commonjs or no type field in package.json) as follows:

const RedisStore = require('rate-limit-redis');

Import it in a ESM project (type: module in package.json) as follows:

import RedisStore from 'rate-limit-redis';

Examples

To use it with a node-redis client:

import rateLimit from 'express-rate-limit';
import RedisStore from 'rate-limit-redis';
import { createClient } from 'redis';

// Create a `node-redis` client
const client = createClient({
    // ... (see https://github.com/redis/node-redis/blob/master/docs/client-configuration.md)
});
// Then connect to the Redis server
await client.connect();

// Create and use the rate limiter
const limiter = rateLimit({
    // Rate limiter configuration
    windowMs: 15 * 60 * 1000, // 15 minutes
    max: 100, // Limit each IP to 100 requests per `window` (here, per 15 minutes)
    standardHeaders: true, // Return rate limit info in the `RateLimit-*` headers
    legacyHeaders: false, // Disable the `X-RateLimit-*` headers

    // Redis store configuration
    store: new RedisStore({
        sendCommand: (...args: string[]) => client.sendCommand(args),
    }),
});
app.use(limiter);

To use it with a ioredis client:

import rateLimit from 'express-rate-limit';
import RedisStore from 'rate-limit-redis';
import RedisClient from 'ioredis';

// Create a `ioredis` client
const client = new RedisClient();
// ... (see https://github.com/luin/ioredis#connect-to-redis)

// Create and use the rate limiter
const limiter = rateLimit({
    // Rate limiter configuration
    windowMs: 15 * 60 * 1000, // 15 minutes
    max: 100, // Limit each IP to 100 requests per `window` (here, per 15 minutes)
    standardHeaders: true, // Return rate limit info in the `RateLimit-*` headers
    legacyHeaders: false, // Disable the `X-RateLimit-*` headers

    // Redis store configuration
    store: new RedisStore({
        // @ts-expect-error - Known issue: the `call` function is not present in @types/ioredis
        sendCommand: (...args: string[]) => client.call(...args),
    }),
});
app.use(limiter);

Configuration

sendCommand

The function used to send commands to Redis. The function signature is as follows:

(...args: string[]) => Promise<number> | number

The raw command sending function varies from library to library; some are given below:

Library	Function
node-redis	async (...args: string[]) => client.sendCommand(args)
ioredis	async (...args: string[]) => client.call(...args)
handy-redis	async (...args: string[]) => client.nodeRedis.sendCommand(args)
tedis	async (...args: string[]) => client.command(...args)
redis-fast-driver	async (...args: string[]) => client.rawCallAsync(args)
yoredis	async (...args: string[]) => (await client.callMany([args]))[0]
noderis	async (...args: string[]) => client.callRedis(...args)

prefix

The text to prepend to the key in Redis.

Defaults to rl:.

resetExpiryOnChange

Whether to reset the expiry for a particular key whenever its hit count changes.

Defaults to false.

License

MIT © Wyatt Johnson

Changelog

V3.3.13

Date: 11/8/2024

:rocket: Features

• Added ai.chat.allowedModels feature to enforce model usage limits, restricting access to specific models based on configuration.

• Added shared documents.

  • Shared documents utilize insts to be able to share data without using bots and tags.

  • Additionally, shared documents can be loaded and unloaded at will.

  • The following functions have been added:

    • os.getSharedDocument(name) - Gets a document that is stored in the current inst.
    • os.getSharedDocument(recordName, inst, name) - Gets a document that is stored in the specified inst.
    • os.getLocalDocument(name) - Gets a document that is stored on this device.
    • os.getMemoryDocument() - Gets a document that is stored in memory and cleared upon refresh.

  • Usage:

    // Get a document stored in this inst named "test"
    const doc = await os.getSharedDocument('test');
    
    // maps work like the Map type (see https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Map)
    const inventory = doc.getMap<number>('inventory');
    
    inventory.set('spoons', 2);
    inventory.set('forks', 3);
    os.log('Number of spoons: ' + inventory.get('spoons'));
    
    // arrays work like regular JavaScript arrays:
    const shoppingList = doc.getArray<string>('shoppingList');
    shoppingList.push('cereal', 'milk', 'eggs');
    
    os.log('Shopping list:', inventory.toArray());
    
    // Text is a special type that makes it easy to work with long strings
    const blogPost = doc.getText('blogPost');
    
    blogPost.insert(0, 'Hello, world!');
    
    os.log('Blog Post:\n', blogPost.toString());
    

:bug: Bug Fixes

• Fixed an issue where CasualOS would prompt for login when trying to join a room using os.joinRoom().